package com.kalvan.mq.consumer;

import lombok.Getter;
import lombok.Setter;
import org.apache.rocketmq.common.protocol.heartbeat.MessageModel;

/**
 * mq消费者配置数据
 *
 * @author chenliang
 */
@Getter
@Setter
public class ConsumerConfig {
    private String tag;
    private String topic;
    private MessageModel messageModel;
    private int threadMin;
    private int threadMax;
}
